package com.apes.framework.plugin.mq.annotation;

import java.lang.annotation.*;

/**
 * 功能：MQ消费者
 *
 * @author xul
 * @create 2018-02-02 16:48
 */
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Consumer {

    /**
     * 事件主题
     */
    String topic();

    /**
     * 是否备份消息
     */
    boolean backup() default true;

    /**
     * 是否事务
     */
    boolean transaction() default true;

    /**
     * 异常消息处理间隔时间（单位：分钟）
     */
    int period() default 10;
}
